package org.cy.websocket.stomp;

import org.cy.websocket.stomp.messaging.Message;

/**
 * Created in 2021-05-08 22:51
 *
 * @author cao.yong
 */
public interface StompWebSocket {

    /**
     * 建立连接
     * @param url 地址
     * @param headers 协议头
     * @param listener 监听
     */
    void connect(String url, StompHeaders headers, StompWebSocketListener listener);

    /**
     * 发送消息
     * @param message byteMessage
     */
    void send(Message<byte[]> message);

    /**
     * 关闭 WebSocket
     */
    void close();
}
